package com.test;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

public class MFQueueAddDemo {
	static List<String> contentList = new ArrayList<>();
	static {
		contentList.add("thread:pool-1-thread-3,time:16:14:45.680,num:3");
		contentList.add("thread:pool-1-thread-4,time:16:14:46.680,num:5");
		contentList.add("thread:pool-1-thread-1,time:16:14:46.684");
		contentList.add("thread:pool-1-thread-1,time:16:14:47.684,num:12");
		contentList.add("thread:pool-1-thread-1,time:16:14:48.684,num:16");
	}
	public static void test(MFQueue queue) {
		List<byte[]> c = contentList.stream().map(o -> o.getBytes()).collect(Collectors.toList());
		queue.addAll(c);
	}
}
